# 用类来包装线程对象
"""
    使用Threading模块创建线程，直接从threading.Thread继承，然后重写__init__方法和run方法

    线程同步（锁Lock和Rlock）
    如果多个线程共同对某个数据修改，则可能出现不可预料的结果，为了保证数据的正确性，需要对多个线程进行同步。

    threadLock.acquire() # 加锁
    threadLock.release() # 解锁
"""
import threading
import time

threadLock = threading.Lock()


class MyThread(threading.Thread):  # 继承父类threading.Thread
    def __init__(self, name, delay, counter):
        threading.Thread.__init__(self)  # 或者super(MyThread, self).__init__()，重构必须要写
        self.name = name  # 定义线程名字（后续可以使用self.getName()获取
        self.delay = delay  # 自定义参数（print_time的延迟时间参数）
        self.counter = counter  # 自定义参数（print_time的计数参数）

    def run(self):  # 把要执行的代码写到run函数里面 线程在创建后会直接运行run函数
        print("开始线程 " + self.name)  # 也可以使用self.getName() 获取线程名
        print_time(self.name, self.delay, self.counter)  # 调用方法
        threadLock.acquire()  # 加锁
        run_sql(self.name, "show tables", self.counter)
        print("退出线程 " + self.name)
        threadLock.release()  # 解锁


def print_time(thread_name, delay, counter):
    while counter:
        time.sleep(delay)
        print("%s: %s" % (thread_name, time.ctime(time.time())))
        counter -= 1


def run_sql(thread_name, sql, counter):
    for i in range(counter):
        print("{}执行sql语句{}：{}".format(thread_name, i, sql))  # 加锁后，必须等该线程执行完并解锁后，下一个进程才能执行


# 创建新线程
thread1 = MyThread("Thread-1", 1, 3)
thread2 = MyThread("Thread-2", 2, 3)

# 开启线程
thread1.start()  # 开始执行线程，会自动执行重构的run函数
thread2.start()

# 添加线程到线程列表
threads = []  # 创建线程池
threads.append(thread1)
threads.append(thread2)

for i in threads:
    i.join()  # 等待所有线程完毕
print("线程全部结束")